package com.shujia.flink.table

import org.apache.flink.table.functions.ScalarFunction

/**
 * 自定义函数
 *
 */
class SubstringFunction extends ScalarFunction {

  //方法名必须时eval， 参数可以随便写
  def eval(s: String, begin: Integer, end: Integer): String = {
    s.substring(begin, end)
  }

}
